﻿/* Copyright © 2008 by Marcus Bengtsson - makkbe@gmail.com   
 * 
 * This file is part of TaskDispatcher.
 *
 * TaskDispatcher is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation, either version 2 of the License, or
 * (at your option) any later version.
 *
 * TaskDispatcher is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with TaskDispatcher.  If not, see <http://www.gnu.org/licenses/>.
 **/

using System;
using System.Collections.Generic;
using System.Text;
using Dispatcher.Interfaces;
using Dispatcher.Logging;

namespace Dispatcher.Dispatching
{
    public class TaskDispatcher : IDispatcher
    {
        private List<ITask> tasks;

        public TaskDispatcher()
        {
            this.tasks = new List<ITask>();
        }

        #region IDispatcher Members

        public void AddTask(ITask t)
        {
            if (!this.tasks.Contains(t))
            {
                tasks.Add(t);
            }

            else Logger.Instance.Log("Task " + t.Name + " already exists", System.Diagnostics.EventLogEntryType.Error);

        }

        public void DispatchTasks(DispatchInterval interval)
        {
            if (tasks.Count == 0)
            {
                Logger.Instance.Log("Trying to dispatch empty task list", System.Diagnostics.EventLogEntryType.Warning);
            }

            else
            {
                foreach(ITask task in tasks)
                {
                    try
                    {
                        if (task.Interval == interval)
                        {
                            task.Execute();
                        }
                    }

                    catch(Exception e)
                    {
                        Logger.Instance.Log(e);
                    }
                }
            }
        }

        #endregion
    }
}
